package com.itheima.protocol.disruptor;

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.TimeUnit;


public class DisruptorDemo {

    public static ConcurrentHashMap<String, Integer> utranUuDataLists = new ConcurrentHashMap<String, Integer>();
    
    
    static{
        utranUuDataLists.put("aaa", 111);
        utranUuDataLists.put("bbb", 222);
        UtranUuEventProducerSingleton.newInstance().saveProducerData(utranUuDataLists, "aaa");
    }

    public static void main(String[] args) throws InterruptedException {
        
        
        
        utranUuDataLists.put("aaa", 111);
        utranUuDataLists.put("bbb", 222);
        UtranUuEventProducerSingleton.newInstance().saveProducerData(utranUuDataLists, "aaa");
    }
}
